package com.qch.concurrent.demo_04_notify_consumer;

/**
 * @Author qch
 * @Date 2021/7/26
 */
public class Main {
    public static void main(String[] args) throws InterruptedException {
        MyQueue myQueue = new MyQueue();
        ConsumerThread consumerThread = new ConsumerThread(myQueue);
        ProducerThread producerThread = new ProducerThread(myQueue);
        producerThread.start();
        consumerThread.start();
        Thread.sleep(5000);
        //进程退出
        System.exit(0);
    }
}
